package org.thanos.demo.consumer;

import org.eclipse.paho.client.mqttv3.MqttException;

/**
 * mqtt 消息处理
 */
public interface MessageHandler {

    void consume() throws MqttException;

    void produce() throws MqttException;
}
